package org.example

import org.apache.spark.sql.SparkSession

object sparksql {
  def main(args: Array[String]): Unit = {
    val spark = SparkSession.builder().appName("sl").master("local[*]").getOrCreate()
    println(spark.version)
    val tt = spark.read.textFile("data/")
    val as = tt.filter(line => line.contains("a")).count()
    val bs = tt.filter(line => line.contains("b")).count()
    println(as, bs)
  }
}
